package com.atguigu.stream.util

import org.apache.spark.streaming.StreamingContext

/**
 * description ：获取StreamingContext及启动
 * author      ：剧情再美终是戏 
 * mail        : 13286520398@163.com
 * date        ：Created in 2020/1/15 19:36
 * modified By ：
 * version:    : 1.0
 */
trait MyApp {

  def main(args: Array[String]): Unit = {
    // 获取 streamSession
    val ssc: StreamingContext = MySparkStreamContextUtil.get(args)

    // 获取数据及转换
    readAndTranform(ssc)

    // 启动 streamingContext
    ssc.start()

    // 让 streamingContext 运行端的driver阻塞，一直运行
    ssc.awaitTermination()
  }

  /**
   * 获取数据及转换
   *
   * @Author 剧情再美终是戏
   * @Date 2020/1/15 19:40
   * @param ssc StreamingContext
   * @return void
   * @Version 1.0
   **/
  def readAndTranform(ssc: StreamingContext)
}
